package com.gengzp.mq.client.interfaces;

import com.gengzp.mq.common.model.resp.GengzpMqMessageExt;

/**
 * @ClassName MqMessageListenerInterface
 * @Description 消息队列框架监听者接口
 * @Author gengzp
 * @Date 2025/6/9 23:23
 */
public interface MqMessageListenerInterface {

    /**
     * 消费消息方法
     *
     * @param message 消息
     */
    void consumeMessage(GengzpMqMessageExt message);

}
